package com.hr.reactive.flux.assignment;

import com.hr.reactive.common.Utils;

import java.nio.file.Path;

public class Main {
    public static void main(String[] args) {
        var path = Path.of("src/main/resources/file.txt");
        var fileImpl = new FileReaderServiceImpl();
        fileImpl.read(path).take(3).subscribe(Utils.subscriber());
    }
}
